package com.heng.test.CG;

public class KafkaService {
    public String produce(String message) {
        System.out.println("Producing Message: " + message);
        return "Message Sent";
    }
}